//package com.kingjw
//
///**
// *
// * @Package: com.kingjw
// * @ClassName: Test
// * @Author: 王坚伟
// * @CreateTime: 2021/11/24 10:31
// * @Description:
// */
//
//
//object StreamWordCount {
//  def main(args: Array[String]): Unit = {
//    // 创建一个表聚合函数实例
//    val top2Temp = new Top2Temp()
//
//    // Table API 的调用
//    val resultTable = sensorTable.groupBy('id)
//      .flatAggregate( top2Temp('temperature) as ('temp, 'rank) )
//      .select('id, 'temp, 'rank)
//
//    // 转换成流打印输出
//    resultTable.toRetractStream[(String, Double, Int)].print("agg temp")
//    resultSqlTable.toRetractStream[Row].print("agg temp sql")
//  }
//}
//
